草庐IT

CountDownLatch和ExecutorService 线程池cachedThreadPool.submit

全部标签

c++ - Windows 操作系统中的线程安全和原子读取

我的应用程序中有这段代码。我怀疑它不是线程安全的,因此决定询问SOers。int*volatileint_ptr;intcount;线程1:voidgrow(intnew_count){if(new_count线程2:intget_value(intindex){returnint_ptr[index];}我知道可以使用CRITICAL_SECTION,但线程1可能一周运行一次,而线程2一天运行数百万次。在99.99999%的访问int_ptr的尝试中,第二个线程将白白进入和退出临界区。这对我来说没有意义。该应用程序只能在Windows2000和更高版本的Intel处理器(显然是多核处

c - 挂起和恢复线程(Windows,C)

我目前正在开发一个高度多线程的应用程序,处理大量要处理的小数据。问题在于产生了太多线程,这大大降低了系统速度。为了避免这种情况,我有一个Handles表,它限制了并发线程的数量。然后,我“WaitForMultipleObjects”,当一个插槽被释放时,我创建了一个新线程,该线程具有自己的数据批处理。现在,我有尽可能多的线程(通常每个内核一个)。即使那样,由多线程引起的负载也是非常明智的。这样做的原因是:数据批处理很小,所以我一直在创建新线程。我当前实现的第一个想法只是将作业重新组合为更长的序列表。因此,当我创建一个新线程时,在终止之前它将有128或512个数据批处理。它运作良好,但

windows - 为什么它像没有线程一样运行?

我正在编写一个脚本来ping我的ip范围。这是我到目前为止所拥有的:lines=`ipconfig`.split("\n")thr=[]ip_line=lines.detect{|l|l=~/IpAddress/i}matcher=/\d+\.\d+\.\d+\.\d+/.match(ip_line)ifmatcher.length>0address=matcher[0]address.sub!(/\.\d+$/,"")(1..254).eachdo|i|xaddr=address+"."+i.to_sputs"pinging#{xaddr}"thr问题是,这执行起来非常慢。就像应用程

c# - 是否可以启动相同的线程?

我有一些计算程序。现在,这个程序是单线程的,我需要增强它以使其成为多线程。一般来说,程序计算,热电路的动态演化(一些配置类型的不同涉及元素(管,泵,active区及其连接),对于每个时间步长程序计算扩散方程(http://en.wikipedia.org/wiki/Diffusion_equation))问题是,在每个时间步上,每个涉及的元素都可以单独处理,但在每个新的时间步上,所有元素都应该相互同步。我决定通过从每个时间步开始每个元素一个线程来解决它。privatevoidSolveElementDynamic(objectelement){if(elementisPJunction

c++ - 如何判断一个线程是否有消息队列?

有什么方法可以通过threadId判断一个线程是否有消息队列?基本上有一些windowsapi只有在线程有消息queue.window时才工作 最佳答案 您可以使用带有线程ID的PostThreadMessage。如果PostThreadMessage返回false且GetLastError返回ERROR_INVALID_THREAD_ID,则线程ID无效或线程没有消息队列。更多信息http://msdn.microsoft.com/en-us/library/ms644946(VS.85).aspx

c++ - 如何正确终止 dll 中的挂起线程?

大家好,我有一个包含错误的第三方库。当我调用一个函数时,它可能会挂起。库函数在dll中被调用。我决定将调用移到线程中并等待一段时间。如果线程完成,则确定。如果不是——我应该强制终止它。此处的简化示例:unsignedCounter=0;voidf(){HANDLEhThread;unsignedthreadID;//Createthesecondthread.hThread=(HANDLE)_beginthreadex(NULL,0,DoSomething,NULL,0,&threadID);if(WAIT_TIMEOUT==WaitForSingleObject(hThread,50

python - 线程后的代码提前执行,为什么?

fromthreadingimportThreadimporttimeprint'startofscript'classMyThread(Thread):defrun(self):foriinxrange(10):print'thread->','['+self.name+']','('+str(i)+')'time.sleep(2)foriinrange(3):my_thread=MyThread()my_thread.name=imy_thread.start()print'endofscript'>>>================================RESTART

c++ - 如何在不等待 C++ 响应的情况下启动线程?

在一个for循环中有一个CreateThread()调用,我希望所有的线程依次启动,每个线程向一个对象写入数据。`$while(ii!=mapOServs.end()){Array_of_Thread_Handles[i]=CreateThread(NULL,0,MyThread,&args[i],0,NULL);}但线程只有在遇到WaitForMultipleObjects或WaitForSingleObject时才会启动。如何在不等待响应的情况下让所有线程依次运行?另外,最好使用什么对象,以便它可以同时被不同的线程修改。 最佳答案

c++ - 创建线程不接受成员函数

我正在尝试为网络编程创建一个类。这将创建一个带线程的通用套接字。但是当我尝试使用createthread()创建线程时。第三个参数是产生错误。从网上我了解到我不能使用成员函数作为createthread()的参数。有什么可以实现的吗? 最佳答案 处理这个问题的最简单方法是创建一个“stub”函数,它会回调到您的类中。UINTtidHANDLEhThread=CreateThread(NULL,0,myThreadStub,this,0,&tid);....unsignedlongWINAPImyThreadStub(void*ptr

windows - 最大线程数

这个问题在这里已经有了答案:What'sthemaximumnumberofthreadsinWindowsServer2003?(8个答案)关闭9年前。Delphi开发的32位和64位应用程序的最大线程数是多少?我需要知道在32位应用程序上同时运行的线程的限制是多少,因为我正在进行性能分析并且我想让操作系统管理正在等待的线程的执行顺序。